from pyflink.datastream import StreamExecutionEnvironment, MapFunction

# 1、创建flink执行环境
env = StreamExecutionEnvironment.get_execution_environment()

# 修改并行度
env.set_parallelism(1)

# 2、读取数据,得到DataStream，相当于RDD  （有界流）
lines_ds = env.read_text_file("G:\LanZhiPeiXun\Flink\data\students.txt")

# 1、使用lambda表达式
names_ds = lines_ds.map(lambda line: line.split(",")[1])
# names_ds.print()

# 2、使用类的对象方式
class StudentMapFunction(MapFunction):

    # map方法每一条数据执行一次
    def map(self, line):
        return line.split(",")[0]

ids_ds = lines_ds.map(StudentMapFunction())

ids_ds.print()

env.execute()

